package com.xiaoran.springcloud.controller;



import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Controller;


@Controller
@EnableBinding(Sink.class)
public class reciverMessageListCOnteoller {

    @Value("${server.port}")
    private String servertport;

    @StreamListener(Sink.INPUT)
    public void input(Message<String> message){
        System.out.println("我是消费者2号 消费的内容是："+message.getPayload()+"\t port:"+servertport);
    }
}
